# 导包
from __future__ import absolute_import, unicode_literals
import os
from celery import Celery

# 环境配置  直接复制manager中的环境配置
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "meiduo_mall.settings.dev")
# 创建celery对象
app = Celery('meiduo')

# 加载配置文件，（任务，结果队列）
app.config_from_object('celery_tasks.config')

# 注册任务
app.autodiscover_tasks(['celery_tasks.sms.tasks', 'celery-tasks.email.tasks'])

# 装饰任务
# @app.task(bind=True)
# def hello_world(self):
#     import time
#     for i in range(0, 10):
#         time.sleep(1)
#         print('i = %s' % i)
